#include "app_mqtt.h"
#include "log/log.h"
#include "unistd.h"
int app_mqtt_recv(char *json)
{ 
    log_debug("处理接受的消息: %s", json);
    // 发送消息
    char *send_json = "{\"conn_type\":1,\"id\":\"5858\",\"msg\":\"61626364\"}";
    app_mqtt_send(send_json);
    return 0;
}
int main(int argc, char const *argv[])
{
    // 初始化MQTT
    app_mqtt_init();
    // 注册接收消息回调
    app_mqtt_registerRecvCallback(app_mqtt_recv);
    
    //等待
    sleep(50);
    // 关闭MQTT
    app_mqtt_close();
    return 0;
}
